package com.tandashi.springbootstudy01.sensor.receiver;

import org.apache.kafka.common.utils.Bytes;

public interface Receiver {

    void receive(Bytes message);

    String topic();

    default String tag(){
        return null;
    }
}
